package personal.wang.producer;

import java.util.List;

/**
 * @className: DataMockProducer
 * @Description:
 * @Author: wangyifei
 * @Date: 2022/6/25 18:15
 */
public interface DataMockProducer {
    void init(String kafkaBootstrap , String txID);
    void close();
    void send(List<String> rds , StringBuilder sb , String topic);
}
